package com.azier.kapacitor.script.node.nodebind;

import com.azier.kapacitor.script.node.Node;
import com.azier.kapacitor.script.node.WindowNode;

/**
* 1 * @Author: luoj
* 2 * @Date: 2019/11/8 11:27
* 3
*/

/**
 Create a new node that windows the stream by time.
**/

/**
创建一个新的window节点，该节点定期发出BarrierMessage
**/
public interface WindowNodeBind extends Node{
    default WindowNode windowNode(){
        WindowNode nextNode = new WindowNode();
        this.setNextNode(nextNode);
        nextNode.zetHeadNode(this.getHeadNode());
        return nextNode;
    }
}